/**
 * 责任链组装实现.
 */
package com.cnpc.bds.sdk.sink.kafka.handler;